package com.xzc.kafka.action.consumer._3CP;

public class ConsumerMain {

    public static void main(String[] args) {
        String topicName = "test-topic1";
        String groupID = "test-group";
        String brokerList = "es1:19092,es2:19092,es3:19092";
        int consumerNum = 3;
        ConsumerGroup consumerGroup = new ConsumerGroup(consumerNum, groupID, topicName, brokerList);
        consumerGroup.execute();
    }
}
